package DataStreamApi.Transformation算子.UDF;

import org.apache.flink.api.common.functions.FilterFunction;

//Flink暴露了所有UDF函数的接口，具体实现方式为接口或者抽象类，例如MapFunction、FilterFunction、ReduceFunction等。所以用户可以自定义一个函数类，实现对应的接口。
public class Flink01_UDF_FILTER implements FilterFunction<String> {

    @Override
    public boolean filter(String value) throws Exception {
        return false;
    }
}
